package org.mxp.demo6;

import com.rabbitmq.client.Channel;
import org.mxp.utils.RabbitMQUtils;

public class SendObj {
    public static void main(String[] args) throws Exception {
        // 交换机名称
        String EXCHANGE_NAME = "logs";
        // 获取信道
        Channel channel = RabbitMQUtils.getChannel();
        // 声明交换机，第一个参数为交换机名称，第二个参数为交换机类型
        channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
        // 定义消息内容
        String message = "hello world ";
        // 发送10条消息
        for (int i = 0; i < 10; i++) {
            channel.basicPublish(EXCHANGE_NAME, "", null, (message + i).getBytes());
        }
        System.out.println("消息发送完毕");
    }
}
